package com.lagou.orderservicerocket.service;

import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Service;

/**
 * @Authther: mrwu
 * @date:2021/5/16-05
 * @Description:com.lagou.orderservicerocket.service
 */
@Slf4j
@Service
@RocketMQMessageListener(consumerGroup = "check-skill-order-consumer", topic = "check-skill-order")
public class OrderCheckListener implements RocketMQListener<String> {
    @Override
    public void onMessage(String message) {

        log.info("处理超时订单");
        //1.接收订单编号
        //2.检查订单状态
        //3.如果订单状态为未支付修改订单状态为已过期

    }

}

